062bd5bc67d1b8362b3c5ebc696e08f525f05810,spring-social-twitter/src/main/java/org/springframework/social/twitter/api/impl/StreamDispatcher.java,StreamDispatcher,handleWarning,#String#,109
Before Change
private void handleWarning(String line) throws IOException {
final StreamWarningEvent warningEvent = objectMapper.readValue(line, StreamWarningEvent.class);
for (final StreamListener listener : listeners) {
new Thread(new Runnable() {
public void run() {
listener.onWarning(warningEvent);
}
}).start();
}
}
After Change
private void handleWarning(String line) throws IOException {
final StreamWarningEvent warningEvent = objectMapper.readValue(line, StreamWarningEvent.class);
for (final StreamListener listener : listeners) {
Future<?> result = pool.submit((new Runnable() {
public void run() {
listener.onWarning(warningEvent);
}
}));
}
}